package cn.com.wangluotongxin.netty.rabbitmq;

import cn.com.wangluotongxin.chat.netty.ChatNettyQueue;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitmqQueue {

    /**
     * 登录
     */
    @Bean
    public Queue login(){
        return new Queue(ChatNettyQueue.CHAT_LOGIN, true);
    }

    /**
     * 登录响应
     */
    @Bean
    public Queue loginResponse(){
        return new Queue(ChatNettyQueue.CHAT_LOGIN_RESPONSE, true);
    }

    /**
     * 离线
     */
    @Bean
    public Queue offLine(){
        return new Queue(ChatNettyQueue.CHAT_OFF_LINE, true);
    }

    /**
     *  发送消息
     */
    @Bean
    public Queue sendMessage(){
        return new Queue(ChatNettyQueue.CHAT_SEND_MESSAGE, true);
    }

    /**
     *  发送消息响应
     */
    @Bean
    public Queue sendMessageResponse(){
        return new Queue(ChatNettyQueue.CHAT_SEND_MESSAGE_RESPONSE, true);
    }

    /**
     * 刷新消息页面
     */
    @Bean
    public Queue chatMessageRead() {
        return new Queue(ChatNettyQueue.CHAT_MESSAGE_HAVE_READ, true);
    }

    /**
     * 事件推送
     */
    @Bean
    public Queue chatEventPush() {
        return new Queue(ChatNettyQueue.CHAT_EVENT_PUSH, true);
    }

    /**
     *  用户系统消息
     */
    @Bean
    public Queue chatSysMessge() {
        return new Queue(ChatNettyQueue.CHAT_SYS_MESSAGE_SEND, true);
    }
}
